const oracledb = require('oracledb');

// 数据库配置
const dbConfig = {
  user: "LIMS",
  password: "vJGT6yPCa#nMWk3y",
  connectString: "10.1.17.15:1521/tqglp"
};

// 测试数据库连接
async function sqlConnect(sqlstr) {
  let connection;
  
  try {
    // 建立连接
    connection = await oracledb.getConnection(dbConfig);    
    // 执行SQL语句
    const result = await connection.execute(sqlstr);    
    console.log('查询结果:', result);
    return result;
  } catch (err) {
    console.error('数据库操作出错:', err);
    // 关键修复：抛出错误，让调用方能够捕获
    throw err;
  } finally {
    // 释放连接
    if (connection) {
      try {
        await connection.close();
        console.log('连接已关闭');
      } catch (err) {
        console.error('关闭连接时出错:', err);
      }
    }
  }
}

module.exports = sqlConnect;